@@ -109,7 +109,7 @@ module Agents |
||
| 109 | 109 |
def receive(incoming_events) |
| 110 | 110 |
mqtt_client.connect do |c| |
| 111 | 111 |
incoming_events.each do |event| |
| 112 |
- c.publish(interpolated(event)['topic'], event) |
|
| 112 |
+ c.publish(interpolated(event)['topic'], event.payload['message']) |
|
| 113 | 113 |
end |
| 114 | 114 |
end |
| 115 | 115 |
end |